package com.shujia.custom.udfdemo;

import org.apache.hadoop.hive.ql.exec.UDF;

/*
    1. 继承：org.apache.hadoop.hive.ql.exec.UDF
 */
public class MyUDFDemo1 extends UDF {
    //传进去一个字符串类型的值，在值的后面拼接一个$符号
    public String evaluate(String obj){
        return obj+"$";
    }

    //需求：1000以下的 +500；1000~2000 +1000；2000以上 +1500
    public int evaluate(int sal){
        if(sal<=1000){
            return sal+500;
        }else if(sal<=2000){
            return sal+1000;
        }else {
            return sal+1500;
        }
    }
}
